package com.hdd.starter.properties;


import lombok.Data;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.LinkedHashSet;
import java.util.Set;

/**
 * 从配置文件获取 canal 配置，前缀是 canal.client
 *
 * @Author: ynz
 * @Date: 2019/4/17/017 8:47
 * @Version 1.0
 */
@Data
public class CanalProperties {


    private static Logger logger                     = LoggerFactory.getLogger(CanalProperties.class);
    private static final String CLASSPATH_URL_PREFIX = "classpath:";
    /**
     * canal 服务器地址，默认是本地的环回地址
     */
    private String host = "127.1.1.1";

    /**
     * canal 服务设置的端口，默认 11111
     */
    private int port = 11111;

    /**
     * 集群 设置的用户名
     */
    private String userName = "";

    /**
     * 集群 设置的密码
     */
    private String password = "";

    /**
     * 批量从 canal 服务器获取数据的最多数目
     */
    private int batchSize = 1000;

    /**
     * 是否有过滤规则
     */
    private String filter;

    /**
     * 当错误发生时，重试次数
     */
    private int retryCount = 5;

    /**
     * 信息捕获心跳时间
     */
    private long acquireInterval = 1000;

    /**
     * 实例名称
     */
    private String key = "example";
}
